import { IMessage } from "../types/message.ts";
import { InsertMessages } from "../db/servers/message";
import { GetSessionsByUser, MergeSession } from "../db/servers/session";
import { ICreateWs } from "../types/ws.ts";

// message:
// 1.拿到离线消息
// 2.给每个消息添加ownerid => 现在登陆的用户
// 3.插入到本地数据

// session ：
// 1.拿到本地session 按照session_id分类
// 2. 判断离线消息的session_id是否存在本地 如果存在 更新就行
// 3.如果不存在 我们就插入新的session
export function MergeMessage(userId: number, remoteMessage: IMessage[], params: ICreateWs) {
  let localSession = GetSessionsByUser(userId);
  //消息拥有者为现在登陆的用户
  InsertMessages(remoteMessage, params.id);
  MergeSession(localSession, remoteMessage);
}
